8203d4dbcf8e61a79b72d5e9ac86bda0ff447e77,src/main/java/org/elasticsearch/transport/netty/NettyTransport.java,NettyTransport,disconnectFromNode,#DiscoveryNode#,752

Before Change



    @Override
    public void disconnectFromNode(DiscoveryNode node) {
        synchronized (connectLock(node.id())) {
            NodeChannels nodeChannels = connectedNodes.remove(node);
            if (nodeChannels != null) {
                try {

After Change


    public void disconnectFromNode(DiscoveryNode node) {
        NodeChannels nodeChannels = connectedNodes.remove(node);
        if (nodeChannels != null) {
            connectionLock.acquire(node.id());
            try {
                    try {
                        nodeChannels.close();